package com.xiaoran.RMQ_1.test7_Topic;

import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.xiaoran.RMQ_1.utlis.RabbitMqUtils;

import java.util.Scanner;

public class Topic_Procuder {
    public static final String name="topic_logs";
    public static void main(String args[]) throws  Exception{
        Channel channel=RabbitMqUtils.getChannel();
        Scanner scanner=new Scanner(System.in);
        while (scanner.hasNext()){
            String message=scanner.next();
            channel.basicPublish(name,"quick.orange.fox",null,message.getBytes());
        }
    }
}
